package com.insight.modules.oss.service.impl;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.insight.common.util.CommonUtils;
import com.insight.common.util.oss.OssBootUtil;
import com.insight.modules.oss.entity.OSSFile;
import com.insight.modules.oss.mapper.OSSFileMapper;
import com.insight.modules.oss.service.IOSSFileService;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;

import java.io.IOException;

@Service("ossFileService")
public class OSSFileServiceImpl extends ServiceImpl<OSSFileMapper, OSSFile> implements IOSSFileService {

	/**
	 * 上传文件到OSS，并保存文件信息到数据库
	 *
	 * @param multipartFile 前端传入的文件对象
	 * @throws IOException 上传过程中可能抛出的IO异常
	 */
	@Override
	public void upload(MultipartFile multipartFile) throws IOException {
		// 获取文件原始名称
		String fileName = multipartFile.getOriginalFilename();
		// 处理文件名，避免重复或非法字符
		fileName = CommonUtils.getFileName(fileName);
		// 创建OSS文件实体
		OSSFile ossFile = new OSSFile();
		// 设置文件名
		ossFile.setFileName(fileName);
		// 调用工具类上传文件，返回文件访问URL
		String url = OssBootUtil.upload(multipartFile,"upload/test");
		// 设置文件URL
		ossFile.setUrl(url);
		// 保存文件信息到数据库
		this.save(ossFile);
	}

	/**
	 * 删除OSS上的文件及数据库记录
	 *
	 * @param ossFile 需要删除的OSS文件实体
	 * @return 删除是否成功，异常则返回false
	 */
	@Override
	public boolean delete(OSSFile ossFile) {
		try {
			if (ossFile == null || ossFile.getId() == null) {
				return false;
			}
			this.removeById(ossFile.getId());
			String url = ossFile.getUrl();
			if (url != null) {
				OssBootUtil.deleteUrl(url);
			}
		}
		catch (Exception ex) {
			return false;
		}
		return true;
	}

}

